/******************************************************************
 *
 *    Java Lib For Waqu Service, Powered By weixulang.
 *
 *    Copyright (c) 2017-2020 waqu Co.,Ltd
 *    http://www.waqu.com/
 *
 *    Package:     test
 *
 *    Filename:    Recv.java
 *
 *    Description: TODO(用一句话描述该文件做什么)
 *
 *    Copyright:   Copyright (c) 2017-2020 
 *
 *    Company:     waqu Co.,Ltd
 *
 *    @author:     weixulang
 *
 *    @version:    1.0.0
 *
 *    Create at:   2017年4月12日 下午2:48:50
 *
 *****************************************************************/
package test.mq;


import com.rabbitmq.client.*;

import java.io.IOException;

public class Recv {

  private final static String QUEUE_NAME = "hello";

  public static void main(String[] argv) throws Exception {
    ConnectionFactory factory = new ConnectionFactory();
    factory.setHost("localhost");
    Connection connection = factory.newConnection();
    Channel channel = connection.createChannel();

    channel.queueDeclare(QUEUE_NAME, false, false, false, null);
    System.out.println(" [*] Waiting for messages. To exit press CTRL+C");

    Consumer consumer = new DefaultConsumer(channel) {
      @Override
      public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body)
          throws IOException {
        String message = new String(body, "UTF-8");
        System.out.println(" [x] Received '" + message + "'");
      }
    };
    channel.basicConsume(QUEUE_NAME, true, consumer);
  }
}
